//建立一个连接池
var mysqlconfig = require("./mysqlconfig");
/**
 * mysql连接池模块
 * @author jeri
 * @time  2016.5.24
 */

var mysql=require("mysql");
/**
 * 连接池建立
 * @pool {object}
 */

var connection = mysql.createPool(mysqlconfig);

/**
 * select和delete操作
 * @param  {string}   sql      sql语句
 * @param  {Function} callback 回调函数
 * @return {none}
 */
var query=function(sql,para,callback){
    connection.getConnection(function(err,conn){
        if(err){

            console.log('CONNECT ERROR:', err.message);
            callback(err,null,null);
        }else{
            conn.query(sql,para,function(qerr,vals,fields){
                //释放连接
                conn.release();
                //事件驱动回调
                callback(qerr,vals,fields);
            });
        }
    });
};


// 暴露接口
module.exports = {query,connection};